package cn.csq.rpc.transport;

import cn.csq.rpc.Peer;

import java.io.IOException;
import java.io.InputStream;

/**
 * @author csq
 * @version 1.0.0
 * @ClassName TransportClient.java
 * @Description 网络通讯协议客户端
 * @createTime 2021年12月19日 22:29:00
 */
public interface TransportClient {

    /**
     * 1. 创建连接
     * 2. 发送数据，并等待响应
     * 3. 关闭连接
     */

    void connect(Peer peer);

    InputStream write(InputStream data) throws IOException;

    void close();

}
